package org.apache.kylin.common.streaming;

import com.google.common.collect.Lists;
import com.google.common.collect.Maps;

import java.io.Serializable;
import java.util.List;
import java.util.Map;

/**
 * Created by taoliu on 2017/1/12.
 */
public class StreamingBatchSegmentsDesc implements Serializable{
    private long startTime;
    private long endTime;
    private List<String> segments = Lists.newArrayList();
    private Map<Long,Long> partitionsOffset = Maps.newHashMap();

    public long getStartTime() {
        return startTime;
    }

    public void setStartTime(long startTime) {
        this.startTime = startTime;
    }

    public long getEndTime() {
        return endTime;
    }

    public void setEndTime(long endTime) {
        this.endTime = endTime;
    }

    public List<String> getSegments() {
        return segments;
    }

    public void setSegments(List<String> segments) {
        this.segments = segments;
    }

    public Map<Long, Long> getPartitionsOffset() {
        return partitionsOffset;
    }

    public void setPartitionsOffset(Map<Long, Long> partitionsOffset) {
        this.partitionsOffset = partitionsOffset;
    }
}
